// Copyright 2018 Grass Valley, A Belden Brand

// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at

//     http://www.apache.org/licenses/LICENSE-2.0

// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

//cTCPStream.h

#pragma once

class cIOBuffer;
struct SOCKET_DATA;

class cTCPStream
{
  typedef std::map<int, vfs::cPtr<cIOBuffer> > tBufferStream;

public:
  cTCPStream();
  ~cTCPStream();

  void NotifyRecvCompleted(vfs::cPtr<cIOBuffer> pIOBuffer, SOCKET_DATA *pSocketData);

private:
  void NewBuffersAvailable(SOCKET_DATA *pSocketData, vfs::iActivity::Ptr activity);

private:
  vfs::cLock m_IncomingAccess;
  tBufferStream m_IncomingBuffers;
  int m_LastSuccessfulPacketNumber;
};
